package com.maikobi.maikobi.bizmq;

import com.maikobi.maikobi.constant.BiMqConstant;
import jakarta.annotation.Resource;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
/**
 * 定义一个消息生产者类，用于向RabbitMQ发送消息
 *
 * @author: Maiko7
 * @create: 2025-07-18 8:23
 */
@Component
public class BiMessageProducer {

    // 注入RabbitTemplate模板，用于发送消息
    @Resource
    private RabbitTemplate rabbitTemplate;

    /**
     * 发送消息到RabbitMQ的方法
     * @param message 待发送的消息内容
     */
    public void sendMessage(String message) {
        // 使用RabbitTemplate模板发送消息到指定的交换机和路由键
        rabbitTemplate.convertAndSend(BiMqConstant.BI_EXCHANGE_NAME, BiMqConstant.BI_ROUTING_KEY, message);
    }
}

